import { cloud } from '@hw-agconnect/cloud-server'
import { user } from './ServerModel/user'

// default是user对象类型使用的存储区名
const collection = cloud.database({ zoneName: 'default' }).collection(user)

export class UserObj {
  query() {
    console.info("运行user的query方法");
    return collection.query().get();

  }

  // 主键有的话就执行更新操作，主键不存在执行插入操作
  upset(users: user[]) {
    return new Promise((resolve, reject) => {
      collection.upsert(users.map(item => user.parseFrom(item)))
        .then(result => resolve({ result }))
        .catch(err => reject(err))
    });
  }
}
